package com.example.gateway.demo;

import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

import java.util.Arrays;

public class Demo1 {

    public static void main(String[] args) {
////        Mono.just("baohuajie").subscribe(System.out::println);
//        String[] array = {"hanhan", "guagua"};
////        Flux.just(array).subscribe(System.out::println);
//        Flux.just(array).doOnComplete(new Runnable() {
//            @Override
//            public void run() {
//                System.out.println(Thread.currentThread().getName());
//            }
//        }).subscribe(s -> {
//        });

//        Flux.just(1, 2, 3)
//                .flatMap(x -> Flux.just(x * 10))
//                .toStream()
//                .forEach(System.out::println);

//        Flux.concat(Mono.just(3), Mono.just(4), Flux.just(1, 2))
//                .subscribe(System.out::println);

//        Flux.just(5, 10,100)
//                .concatMap(x -> Flux.just(x * 10, 100))
//                .toStream()
//                .forEach(System.out::println);

//        Flux.just(1, 2)
//                .flatMap(x -> Flux.just(x * 10, 100))
//                .toStream()
//                .forEach(System.out::println);

        Flux.just(5, 10, 100)
                .next()
                .doOnSuccess(s -> System.out.println(s));
    }

}
